package com.enjoyor.soa.traffic.api.service.dubbo.redis;

import com.enjoyor.soa.traffic.util.pojo.ResultPojo;

/**
 * redis消息发布
 * @ClassName: PubMsgService
 * @Description: TODO
 * @author: Administrator
 * @date: 2018年10月26日 下午2:23:38
 */
//@Service(protocol = { "dubbo" })
public interface DubboRedisToolService {

	public ResultPojo initPublish(String channel);
	/**
	 * 
	 * @Title: PubMsg
	 * @Description: 发布消息
	 * @param topic
	 * @param message
	 * @return
	 * @return: ResultPojo
	 */
	public ResultPojo publish(String channel, String message); 

	
	/**
	 * 
	 * @Title: subscribe
	 * @Description: TODO
	 * @param channel
	 * @return: void
	 */
	public void initSubscribe(String channel);
	
	/**
	 * 
	 * @Title: setListenFlag
	 * @Description: TODO
	 * @param channel
	 * @param flag
	 * @return: void
	 */
	public void setListenFlag(String system,String channel, boolean flag);
}
